package p.ithorns.integration.hazelcast.mqtt;

import java.io.Serializable;

/**
 * AbstractDataHandler
 * <p>
 * 数据处理器抽象类
 *
 * @author liuhaitao
 * @version 1.0
 * @date 2022/3/15 13:37
 */
public abstract class AbstractDataHandler<E> implements DataHandler<E> {

    public AbstractDataHandler() {
        register();
    }

    /**
     * 获取类型
     *
     * @return DevCode
     */
    public abstract Serializable getCode();

    public void register() {
        // 自注册
        DataHandlerContext.register(getCode(), this);
    }

}
